9441f715f2d699c372d86c149f203918880ce30d,sql/src/main/java/io/crate/protocols/postgres/SimplePortal.java,SimplePortal,sync,#Planner#StatsTables#,160

Before Change


        }
        statsTables.logExecutionStart(jobId, query);
        StatsTablesUpdateListener statsTablesUpdateListener = new StatsTablesUpdateListener(jobId, statsTables);
        resultReceiver.completionFuture().whenComplete(statsTablesUpdateListener);

        if (!analysis.analyzedStatement().isWriteOperation()) {
            resultReceiver = new ResultReceiverRetryWrapper(

After Change



        statsTables.logExecutionStart(jobId, query);
        StatsTablesUpdateListener statsTablesUpdateListener = new StatsTablesUpdateListener(jobId, statsTables);
        CompletableFuture completableFuture = resultReceiver.completionFuture().whenComplete(statsTablesUpdateListener);

        if (!resumeIfSuspended()) {
            rowReceiver = new RowReceiverToResultReceiver(resultReceiver, maxRows);
            portalContext.getExecutor().execute(plan, rowReceiver, this.rowParams);
        }
        synced = true;
        return completableFuture;
    }

    @Override